一个基于storm+flume+kafka的可运行程序包(A storm+flume+kafka based executable package)

自定义简单Kafka消费者,里面有对kafka的简单引用(Customize simple Kafka consumers with a simple reference to Kafka)

kafka0.10->flume1.8->elasticsearch 6.0 自定义日志解析类，自定义索引名,Kafkasource 修改从最后ｏｆｆｓｅｔ开始读。　(Kafka 0.10 to flume 1.8 to elasticsearch 6 Customize the log parsing class, customize the index name, and read the Kafkasource changes from the last offset.)